package org.apache.rocketmq.broker.longpolling;

import org.apache.rocketmq.store.MessageArrivingListener;

import java.util.Map;

/**
 * @课程描述:从零带你写框架系列中的课程，整个系列包含netty，xxl-job，rocketmq，nacos，sofajraft，spring，springboot，disruptor，编译器，虚拟机等等。
 * @author：陈清风扬，个人微信号：chenqingfengyangjj。
 * @date:2025/6/25
 * @方法描述：在第十三版本代码还用不到这个类，引入进来只是为了程序不报错
 */
public class NotifyMessageArrivingListener implements MessageArrivingListener {
    // private final PullRequestHoldService pullRequestHoldService;
    // private final PopMessageProcessor popMessageProcessor;
    // private final NotificationProcessor notificationProcessor;
    //
    // public NotifyMessageArrivingListener(final PullRequestHoldService pullRequestHoldService, final PopMessageProcessor popMessageProcessor, final NotificationProcessor notificationProcessor) {
    //     this.pullRequestHoldService = pullRequestHoldService;
    //     this.popMessageProcessor = popMessageProcessor;
    //     this.notificationProcessor = notificationProcessor;
    // }

    @Override
    public void arriving(String topic, int queueId, long logicOffset, long tagsCode,
                         long msgStoreTime, byte[] filterBitMap, Map<String, String> properties) {
        // this.pullRequestHoldService.notifyMessageArriving(topic, queueId, logicOffset, tagsCode,
        //         msgStoreTime, filterBitMap, properties);
        // this.popMessageProcessor.notifyMessageArriving(topic, queueId);
        // this.notificationProcessor.notifyMessageArriving(topic, queueId);
    }
}